Node / reticulum_mirror / MeshChatX / files / meshchatx / src / frontend / js / messages / usePaperIngest.js

Displaying Raw • Download

T8b949e// @ts-check

Tff7b72import Tb4b4b4{ Te6edf3ref Tb4b4b4} Tff7b72from Ta5d6ff"vue"Tb4b4b4;

Tff7b72import Te6edf3ToastUtils Tff7b72from Ta5d6ff"../ToastUtils.js"Tb4b4b4;

Tff7b72import Te6edf3WebSocketConnection Tff7b72from Ta5d6ff"../WebSocketConnection.js"Tb4b4b4;

Tff7b72import Tb4b4b4{

Te6edf3isPaperMessageIngested Tff7b72as Te6edf3isPaperMessageIngestedStoredTb4b4b4,

Te6edf3listIngestedPaperMessageHashesTb4b4b4,

Te6edf3markPaperMessageIngestedTb4b4b4,

Te6edf3normalizePaperIngestMessageHashTb4b4b4,

Te6edf3shouldMarkPaperIngestFromResultStatusTb4b4b4,

Tb4b4b4} Tff7b72from Ta5d6ff"../../components/messages/conversationPaperIngest.js"Tb4b4b4;

T8b949e/**

* Paper-message ingest state for ConversationViewer: the pending ingest

* result hash, the identity-scoped ingested-hash map, WS ingest request,

* and the lxm.ingest_uri result handler.

*

* options.getIdentityKey resolves the active identity bucket the ingested

* hashes are stored under. options.t is the host i18n function.

*/

Tff7b72export Tff7b72function Te6edf3usePaperIngestTb4b4b4(Te6edf3options Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3getIdentityKey Tff7b72= Te6edf3optionsTb4b4b4.Te6edf3getIdentityKey Tff7b72|| Tb4b4b4(Tb4b4b4(Tb4b4b4) Tb4b4b4=> Ta5d6ff"_"Tb4b4b4)Tb4b4b4;

Tff7b72const Te6edf3t Tff7b72= Te6edf3optionsTb4b4b4.Te6edf3t Tff7b72|| Tb4b4b4(Tb4b4b4(Te6edf3keyTb4b4b4) Tb4b4b4=> Te6edf3keyTb4b4b4)Tb4b4b4;

Tff7b72const Te6edf3pendingPaperIngestMessageHash Tff7b72= Te6edf3refTb4b4b4(Tff7b72nullTb4b4b4)Tb4b4b4;

T8b949e/** @type {import("vue").Ref<Record<string, boolean>>} */

Tff7b72const Te6edf3ingestedPaperMessageHashes Tff7b72= Te6edf3refTb4b4b4(Tb4b4b4{Tb4b4b4}Tb4b4b4)Tb4b4b4;

Tff7b72function Te6edf3reloadIngestedPaperMessageHashesTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3hashes Tff7b72= Te6edf3listIngestedPaperMessageHashesTb4b4b4(Te6edf3getIdentityKeyTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4;

T8b949e/** @type {Record<string, boolean>} */

Tff7b72const Te6edf3next Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4;

Tff7b72for Tb4b4b4(Tff7b72const Te6edf3hash Tff7b72of Te6edf3hashesTb4b4b4) Tb4b4b4{

Te6edf3nextTb4b4b4[Te6edf3hashTb4b4b4] Tff7b72= Tff7b72trueTb4b4b4;

Tb4b4b4}

Te6edf3ingestedPaperMessageHashesTb4b4b4.Te6edf3value Tff7b72= Te6edf3nextTb4b4b4;

Tb4b4b4}

Tff7b72function Te6edf3isPaperMessageIngestedTb4b4b4(Te6edf3chatItemTb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3hash Tff7b72= Te6edf3normalizePaperIngestMessageHashTb4b4b4(Te6edf3chatItemTff7b72?Tb4b4b4.Te6edf3lxmf_messageTff7b72?Tb4b4b4.Te6edf3hashTb4b4b4)Tb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3hashTb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72falseTb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3ingestedPaperMessageHashesTb4b4b4.Te6edf3valueTb4b4b4[Te6edf3hashTb4b4b4]Tb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72trueTb4b4b4;

Tb4b4b4}

Tff7b72return Te6edf3isPaperMessageIngestedStoredTb4b4b4(Te6edf3getIdentityKeyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3hashTb4b4b4)Tb4b4b4;

Tb4b4b4}

Tff7b72async Tff7b72function Te6edf3ingestPaperMessageTb4b4b4(Te6edf3uriTb4b4b4, Te6edf3messageHash Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Tff7b72try Tb4b4b4{

Tff7b72const Te6edf3hash Tff7b72= Te6edf3normalizePaperIngestMessageHashTb4b4b4(Te6edf3messageHashTb4b4b4)Tb4b4b4;

Te6edf3pendingPaperIngestMessageHashTb4b4b4.Te6edf3value Tff7b72= Te6edf3hash Tff7b72|| Tff7b72nullTb4b4b4;

Te6edf3WebSocketConnectionTb4b4b4.Te6edf3sendTb4b4b4(

Tffa657JSONTb4b4b4.Te6edf3stringifyTb4b4b4(Tb4b4b4{

Te6edf3typeTff7b72: Ta5d6ff"lxm.ingest_uri"Tb4b4b4,

Te6edf3uriTff7b72: Te6edf3uriTb4b4b4,

Tb4b4b4}Tb4b4b4)

Tb4b4b4)Tb4b4b4;

Te6edf3ToastUtilsTb4b4b4.Te6edf3infoTb4b4b4(Te6edf3tTb4b4b4(Ta5d6ff"messages.ingesting_paper_message"Tb4b4b4)Tb4b4b4)Tb4b4b4;

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{

Te6edf3consoleTb4b4b4.Te6edf3errorTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4;

Te6edf3pendingPaperIngestMessageHashTb4b4b4.Te6edf3value Tff7b72= Tff7b72nullTb4b4b4;

Te6edf3ToastUtilsTb4b4b4.Te6edf3errorTb4b4b4(Te6edf3tTb4b4b4(Ta5d6ff"messages.failed_ingest_paper"Tb4b4b4)Tb4b4b4)Tb4b4b4;

Tb4b4b4}

Tb4b4b4}

Tff7b72function Te6edf3onLxmIngestUriResultEventTb4b4b4(Te6edf3jsonTb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3pendingHash Tff7b72= Te6edf3pendingPaperIngestMessageHashTb4b4b4.Te6edf3valueTb4b4b4;

Te6edf3pendingPaperIngestMessageHashTb4b4b4.Te6edf3value Tff7b72= Tff7b72nullTb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3pendingHash Tff7b72|| Tff7b72!Te6edf3shouldMarkPaperIngestFromResultStatusTb4b4b4(Te6edf3jsonTff7b72?Tb4b4b4.Te6edf3statusTb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72returnTb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3list Tff7b72= Te6edf3markPaperMessageIngestedTb4b4b4(Te6edf3getIdentityKeyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3pendingHashTb4b4b4)Tb4b4b4;

Tff7b72const Te6edf3next Tff7b72= Tb4b4b4{ Tb4b4b4...Te6edf3ingestedPaperMessageHashesTb4b4b4.Te6edf3value Tb4b4b4}Tb4b4b4;

Tff7b72for Tb4b4b4(Tff7b72const Te6edf3hash Tff7b72of Te6edf3listTb4b4b4) Tb4b4b4{

Te6edf3nextTb4b4b4[Te6edf3hashTb4b4b4] Tff7b72= Tff7b72trueTb4b4b4;

Tb4b4b4}

Te6edf3nextTb4b4b4[Te6edf3pendingHashTb4b4b4] Tff7b72= Tff7b72trueTb4b4b4;

Te6edf3ingestedPaperMessageHashesTb4b4b4.Te6edf3value Tff7b72= Te6edf3nextTb4b4b4;

Tb4b4b4}

Tff7b72return Tb4b4b4{

Te6edf3pendingPaperIngestMessageHashTb4b4b4,

Te6edf3ingestedPaperMessageHashesTb4b4b4,

Te6edf3reloadIngestedPaperMessageHashesTb4b4b4,

Te6edf3isPaperMessageIngestedTb4b4b4,

Te6edf3ingestPaperMessageTb4b4b4,

Te6edf3onLxmIngestUriResultEventTb4b4b4,

Tb4b4b4}Tb4b4b4;

Tb4b4b4}